package com.ql.consumer.service;

;
import com.ql.consumer.exception.MessageException;
import com.ql.consumer.service.impl.IMessageProducer;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;


public class Producer implements IMessageProducer {

	private static final Log log = LogFactory.getLog(Producer.class);


	@Override
	public boolean publish(String topic, String message) throws MessageException {
		throw new MessageException("TODO...");
	}
}
